package net.fruit.mq.client.transaction;

import net.fruit.mq.client.Message;

/**
 * 回查本地事务，有Broker回调Producer
 */
public interface LocalTransactionChecker {
    /**
     * 回查本地事务，Broker回调Producer，将未结束的事务发给Producer，由Producer来再次决定事务是提交还是回滚
     *
     * @param msg
     *         消息
     *
     * @return 事务状态
     */
    public TransactionStatus check(final Message msg);
}
